package cn.kgc.entity;

import com.baomidou.mybatisplus.annotation.*;
import com.baomidou.mybatisplus.extension.activerecord.Model;
import com.fasterxml.jackson.annotation.JsonInclude;
import lombok.*;

import java.io.Serializable;

/**
 * @author YC
 */
@Setter
@Getter
@AllArgsConstructor
@NoArgsConstructor
@Builder
@TableName(value = "message_info")
@JsonInclude()
public class MessageInfo extends Model<MessageInfo> implements Serializable {

    /**
     * 主键 消息ID
     * 不让MybatisPlus自动生成主键(type = IdType.ASSIGN_ID)，因为如果消息重新被放入数据库ID不能变化
     */
    @TableId
    private String id;


    /**
     * 微服务名称
     */
    @TableField(value = "service")
    private String service;


    /**
     * 队列名称
     */
    @TableField(value = "queue")
    private String queue;


    /**
     * 交换机名称
     */
    @TableField(value = "exchange")
    private String exchange;


    /**
     * 路由key
     */
    @TableField(value = "routing_Key")
    private String routingKey;


    /**
     * 次数
     */
    @TableField(value = "sequence")
    private Integer sequence;


    /**
     * 消息状态（待发送、待消费、已死亡）
     */
    @TableField(value = "status")
    private String status;


    /**
     * 消息发送时的延迟时间
     * 值为0 不是延迟消息（需要判断消息是否进入交换机和队列）
     * 值不为0 是延迟消息（只需判断消息是否进入延迟交换机）
     */
    @TableField(value = "delay_time")
    private Long delayTime;


    /**
     * 消息的载体
     */
    @TableField(value = "payload")
    private String payload;


    /**
     * 乐观锁
     */
    @Version
    @TableField(value = "version", fill = FieldFill.INSERT)
    private int version;


}
